954745a5d7cdbc625ca9bf7a2662fabd187cae5c,test/io/tetrapod/raft/RaftEngineTester.java,RaftEngineTester,sendAppendEntries,#number#number#number#number#number#Entry[]#number#AppendEntriesResponseHandler#,210

Before Change


         final Entry<TestStateMachine>[] entries, final long leaderCommit, final AppendEntriesResponseHandler handler) {
      final RaftEngine<TestStateMachine> r = rafts.get(peerId);
      if (r != null) {
         executor.schedule(new Runnable() {
            public void run() {
               try {
                  r.handleAppendEntriesRequest(term, leaderId, prevLogIndex, prevLogTerm, entries, leaderCommit, handler);
               } catch (Throwable t) {
                  logger.error(t.getMessage(), t);
               }
            }
         }, randomDelay(), TimeUnit.MILLISECONDS);
      }
   }

After Change


         final Entry<TestStateMachine>[] entries, final long leaderCommit, final AppendEntriesResponseHandler handler) {
      final RaftEngine<TestStateMachine> r = rafts.get(peerId);
      if (r != null) {
         executor.schedule(() -> {
            try {
               r.handleAppendEntriesRequest(term, leaderId, prevLogIndex, prevLogTerm, entries, leaderCommit, handler);
            } catch (Throwable t) {
               logger.error(t.getMessage(), t);
            }
         }, randomDelay(), TimeUnit.MILLISECONDS);
      }
   }